package com.zhss.service;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface MessageService {

    @Input("my-test-queue")
    SubscribableChannel testQueue();

}